from io import BytesIO
from pptx import Presentation
from pptx.oxml.ns import qn


class RAGFlowPptParser(object):
    def __init__(self):
        super().__init__()

    def __extract(self, shape):
        try:
            # Check if shape has text and handle it
            if shape.has_text_frame:
                return shape.text_frame.text
            # TODO 利用subprocess转换后出现了新的情况 13 和 9
            # Handle table shapes (shape_type == 19)
            if shape.shape_type == 19:
                tb = shape.table
                rows = []
                for i in range(1, len(tb.rows)):
                    row_text = "; ".join(
                        [tb.cell(0, j).text + ": " + tb.cell(i, j).text for j in range(len(tb.columns)) if
                         tb.cell(i, j)]
                    )
                    rows.append(row_text)
                return "\n".join(rows)

            # Handle group shapes (shape_type == 6)
            if shape.shape_type == 6:
                texts = []
                for p in sorted(shape.shapes, key=lambda x: (x.top // 10, x.left)):
                    t = self.__extract(p)
                    if t:
                        texts.append(t)
                return "\n".join(texts)

        except NotImplementedError as e:
            print(f"Shape type not implemented: {e}")
            return None

        # Log or handle unsupported shape types
        print(f"Unsupported shape type: {shape.shape_type}")
        return None

    def __call__(self, fnm, from_page, to_page, callback=None):
        try:
            # Open the presentation
            ppt = Presentation(fnm) if isinstance(fnm, str) else Presentation(BytesIO(fnm))
        except Exception as e:
            print(f"Error opening presentation: {e}")
            return []

        txts = []
        self.total_page = len(ppt.slides)

        for i, slide in enumerate(ppt.slides):
            if i < from_page:
                continue
            if i >= to_page:
                break

            texts = []
            for shape in sorted(
                    slide.shapes, key=lambda x: ((x.top if x.top is not None else 0) // 10, x.left)
            ):
                txt = self.__extract(shape)
                if txt:
                    texts.append(txt)

            txts.append("\n".join(texts))

        return txts